f4e1065b6d270f67009fadf78f709a422cbd3b9d,metron-platform/metron-management/src/test/java/org/apache/metron/management/KafkaFunctionsIntegrationTest.java,KafkaFunctionsIntegrationTest,setupKafka,#,59

Before Change


    Properties properties = new Properties();
    kafkaComponent = getKafkaComponent(properties, new ArrayList<>());

    runner = new ComponentRunner.Builder()
            .withComponent("kafka", kafkaComponent)
            .withMillisecondsBetweenAttempts(5000)
            .withNumRetries(5)
            .build();
    runner.start();
  }

After Change


  public static void setupKafka() throws Exception {

    Properties properties = new Properties();
    zkServerComponent = getZKServerComponent(properties);
    kafkaComponent = getKafkaComponent(properties, new ArrayList<>());

    runner = new ComponentRunner.Builder()
            .withComponent("zk", zkServerComponent)
            .withComponent("kafka", kafkaComponent)
            .withMillisecondsBetweenAttempts(5000)
            .withNumRetries(5)
            .withCustomShutdownOrder(new String[]{"kafka","zk"})
            .build();
    runner.start();
  }